package com.woniuxy.email;

import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * @author yellow Docter
 * @date 2024-10-23
 * @desc 蜗牛创想：www.woniuxy.com
 */
@SpringBootTest
public class MQTest02 {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void send01(){
        /**
         *  参数1： 交换机
         *  参数2： 路由 (fanout 不需要路由)
         *  参数3： 消息 (数据 (可以是字符串 或者对象 ))
         */
        String msg = "村长通知:没人家交粮 200近";
        rabbitTemplate.convertAndSend("fanout.exchange",
                null,msg);

    }

    /**
     * 测试 direct 交换机
     */
    @Test
    public void send02(){
        /**
         *  参数1： 交换机
         *  参数2： 路由 (fanout  绑定的时候的字符串 )
         *  参数3： 消息 (数据 (可以是字符串 或者对象 ))
         */
        rabbitTemplate.convertAndSend("direct.exchange",
                "sz","sz的同学发奖金300块");

        rabbitTemplate.convertAndSend("direct.exchange",
                "gz","gz的同学发奖金400块 + 一碗猪脚饭");

    }

}
